package com.qf.utils;

import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.retry.ExponentialBackoffRetry;

/**
 * @author 千锋教育
 * @Company http://www.mobiletrain.org/
 * @Version 1.0
 */
public class ZkClientUtils {
    public static CuratorFramework getClient() {
        //参数1 ，重试连接等待时间  参数2： 重试的次数
        RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);

        //retryPolicy 重试策略： 如果连接不上，重试方案
        //connectString  连接字符串（ip:端口号）
        CuratorFramework client = CuratorFrameworkFactory.builder().retryPolicy(retryPolicy).connectString("192.168.200.158:2182,192.168.200.158:2183,192.168.200.158:2184").build();
        //启动客户端
        client.start();

        return client;
    }
}
